package com.ada.spark.action

import org.apache.spark.{SparkConf, SparkContext}

/**
  * 作用：返回RDD中元素的个数
  */
object Demo3_count {
    def main(args: Array[String]): Unit = {
        //创建SparkConf
        val conf = new SparkConf().setAppName("Demo3_count").setMaster("local[*]")
        //创建Spark上下文对象
        val sc = new SparkContext(conf)

        val rdd = sc.parallelize(1 to 10)

        //在驱动程序中，以数组的形式返回数据集的所有元素。
        println(rdd.count)
        //10
    }
}
